'use strict';
// 通过 require 引入 vk 实例
const vk = require('vk-unicloud');
// 通过 vk.init 初始化 vk实例（只有初始化后才能使用）
vk.init({
	baseDir: __dirname,
	requireFn: require
});
exports.main = async (event, context) => {
	const res = {
		"err_no": 0,
		"err_tips": "success"
	}
	//event为客户端上传的参数
	console.log('event : ', event)


	const body = JSON.parse(event.body)

	if (body.type == "album_audit") {
		console.log("剧审核结果，没有剧集id");
		const msg = body.msg;

		const album_id = msg.match(/"album_id":(\d+)/)[1];
		console.log("album_id", album_id);

		const audit_status = msg.match(/"audit_status":(\d+)/)[1]
		console.log("audit_status", audit_status);

		const ma_app_id = msg.match(/"ma_app_id":"([^"]*)"/)[1];
		console.log("ma_app_id", ma_app_id);
		
		// 审核备注
		const audit_msg = msg.match(/"audit_msg":"([^"]*)"/)[1];
		console.log("audit_msg", audit_msg);
		
		// 能力列表
		const scope_list = msg.match(/"scope_list":\s*\[([^\]]*)\]/)[1];
		console.log("audit_msg", scope_list);

		// 修改数据库状态

		if (audit_status == 2) {
			console.log("通过,可播放，可上线");
			let num = await vk.baseDao.update({
				dbName: "dy_tv", // 表名
				whereJson: { // 条件
					album_id: album_id,
				},
				dataJson: { // 需要修改的数据
					audit_status: 3,
					audit_msg:audit_msg,
					scope_list:scope_list
				}
			});
		}
		if (audit_status == 1) {
			console.log("未通过，不可播放，不可上线");
			let num = await vk.baseDao.update({
				dbName: "dy_tv", // 表名
				whereJson: { // 条件
					album_id: album_id,
				},
				dataJson: { // 需要修改的数据
					audit_status: 4,
					audit_msg:audit_msg,
					scope_list:scope_list
				}
			});
		}

		let ids = await vk.baseDao.add({
			dbName: "dy_hdnews", // 表名
			dataJson: {
				ma_app_id: ma_app_id,
				album_id: album_id,
				audit_status: audit_status,
				shjg:"剧审核结果，没有剧集id",
				audit_msg:audit_msg,
				scope_list:scope_list
			}

		});

		console.log("ids====", ids);
	}
	if (body.type == "upload_video") {
		console.log("视频上传结果");
		const msg = body.msg;

		const open_video_id = msg.match(/"open_video_id":"([^"]*)"/)[1];
		console.log("open_video_id", open_video_id);

		const success = msg.match(/"success":true/)[0];
		console.log("success", success);

		const ma_app_id = msg.match(/"ma_app_id":"([^"]*)"/)[1];
		console.log("ma_app_id", ma_app_id);

		let ids = await vk.baseDao.add({
			dbName: "dy_hdnews", // 表名
			dataJson: {
				ma_app_id: ma_app_id,
				open_video_id: open_video_id,
				success: success,
				shjg:"视频上传结果"
			}

		});

		console.log("ids====", ids);

	}


	//返回数据给客户端
	return res
};